create user ya_practicum with password 'ya_practicum';

create database ya_practicum_db;

grant all privileges on database "ya_practicum_db" to ya_practicum;

\connect ya_practicum_db;

set role ya_practicum;

create schema sandbox;

create table sandbox.kafka_topic(
load_date timestamptz default now() not null,
data jsonb not null
);
